package com.gengzp.mq.server.model.message.req;

import com.gengzp.mq.server.enums.MqMessageStatusEnums;

import java.io.Serial;
import java.io.Serializable;

/**
 * @ClassName MqPageMessageReq
 * @Description 分页查询消息请求实体
 * @Author gengzp
 * @Date 2025/9/1 15:37
 */
public class MqPageMessageReq implements Serializable {

    @Serial
    private static final long serialVersionUID = -5564667041035027600L;

    /**
     * 页码
     */
    private Integer pageNum;

    /**
     * 每页数据条数
     */
    private Integer pageSize;

    /**
     * 偏移量
     */
    private Integer offset;

    /**
     * 消息唯一标识
     */
    private String messageId;

    /**
     * 主题
     */
    private String topic;

    /**
     * 消息状态
     * {@link MqMessageStatusEnums}
     */
    private Integer status;

    public Integer getPageNum() {
        return pageNum;
    }

    public void setPageNum(Integer pageNum) {
        this.pageNum = pageNum;
    }

    public Integer getPageSize() {
        return pageSize;
    }

    public void setPageSize(Integer pageSize) {
        this.pageSize = pageSize;
    }

    public Integer getStatus() {
        return status;
    }

    public void setStatus(Integer status) {
        this.status = status;
    }

    public String getTopic() {
        return topic;
    }

    public void setTopic(String topic) {
        this.topic = topic;
    }

    public String getMessageId() {
        return messageId;
    }

    public void setMessageId(String messageId) {
        this.messageId = messageId;
    }

    public Integer getOffset() {
        return offset;
    }

    public void setOffset(Integer offset) {
        this.offset = offset;
    }

}
